package icu.zlz.common.rabbitmq.configure;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {
    public static final String PHONE_QUEUE = "PhoneQueue";
    public static final String EMAIL_QUEUE = "EmailQueue";

    public static final String MQTT_MSG_QUEUE = "EmailQueue";


    @Bean
    public Queue PhoneQueue() {
        return new Queue(PHONE_QUEUE, true); // true 表示队列持久化
    }

    @Bean
    public Queue emailQueue() {
        return new Queue(EMAIL_QUEUE, true); // true 表示队列持久化
    }
}
